# test_mysql_connection.py
import pymysql


def test_mysql_direct():
    try:
        connection = pymysql.connect(
            host='127.0.0.1',
            user='root',
            password='123456',
            port=3306,
            charset='utf8'
        )
        print("✅ MySQL 直接连接成功！")

        # 检查数据库是否存在
        cursor = connection.cursor()
        cursor.execute("SHOW DATABASES LIKE 'pachong'")
        result = cursor.fetchone()
        if result:
            print("✅ 数据库 'mydb' 存在")
        else:
            print("❌ 数据库 'mydb' 不存在")

        connection.close()

    except pymysql.err.OperationalError as e:
        print(f"❌ MySQL 连接失败: {e}")
        print("请检查以下信息：")
        print("1. MySQL 服务是否启动")
        print("2. 用户名和密码是否正确")
        print("3. 端口是否正确")


if __name__ == "__main__":
    test_mysql_direct()